<?php
namespace app\queue\controller;

use app\BaseController;
use think\queue\Job;

// 处理队列
class Dong extends BaseController
{

    /**
     * fire方法是消息队列默认调用的方法
     *
     * use think\queue\Job; 引入Job类 且放入形参public function fire(Job $job, $data)
     *
     * @param Job            $job      当前的任务对象
     * @param array|mixed    $data     发布任务时自定义的数据
     */
    public function fire(Job $job, $data)
    {
        // 重新发布任务，延迟2秒后再执行
        $job->release(2);

        // 如果任务执行成功， 记得删除任务
        $job->delete();
    }





}